package com.lcxw.hxzbim.activemq;

import com.alibaba.fastjson.JSONObject;
import javax.annotation.Resource;
import org.springframework.jms.annotation.JmsListener;
import org.springframework.stereotype.Component;
import com.lcxw.hxzbim.netty.realization.ImRealization;

@Component
public class Consumer {

    @Resource
    ImRealization imRealization;

    //topic模式的消费者
    @JmsListener(destination = "room", containerFactory = "topicListener")
    public void readActiveQueue(JSONObject message) {
        imRealization.imLoginReply(message);
    }
}
